package com.ruoyi.ly.controller;

import com.ruoyi.common.core.web.controller.BaseController;
import com.ruoyi.wwc.user.domain.User;
import com.ruoyi.wwc.user.service.IUserService;

import com.ruoyi.wwc.user.service.impl.UserServiceImpl;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RestController;

import javax.websocket.Session;
import java.io.IOException;
import java.util.ArrayList;
import java.util.List;

@RestController
public class Fa extends BaseController {


    @RequestMapping("/fa")
    public String fa() throws IOException, IOException {
        //获取yonghuid
//        List<User> list = userService.selectUserList(new User());
//        List<String> ids = new ArrayList<>();
//        System.out.println(ids);
        // 创建一个通知公告
        // 把该通知公告加入到数据库
        // 如果该通知公告只告知某一个人 -- 获取这个人的userId
        String userId = "12";
        Session session = WsServerEndpont.sessionMap.get(userId);
        if (session != null) {  // 在线
            session.getBasicRemote().sendText("你有新消息需要查看!");
        }
        return "新增成功！";
    }
}
